package com.jun.admin.core.model.constant;

/**
 * @author yuejun.li
 * @date 2024/8/13 11:35:44
 */
public class RedisKeyConstant {

    //redis的队列（基于list）
    public static final String REDIS_QUEUE_KEY = "redis:list:mq:";

    //redis的待定队列（基于list）
    public static final String REDIS_PENDING_QUEUE_KEY = "redis:list:mq:backlog:";

    //redis的队列（基于sortedSet）
    public static final String REDIS_ZSET_QUEUE_KEY = "redis:zset:mq:";

    //redis的频道
    public static final String REDIS_JUN_CHANNLE = "com.jun.channel";

    //redis的stream消费者组
    public static final String REDIS_STREAM_CONSUMER_GROUP = "redis:stream:consumer:group:";

    //redis的stream队列
    public static final String REDIS_STREAM_QUEUE = "redis:stream:queue:";

    //redis的stream消费者1
    public static final String REDIS_STREAM_CONSUMER_1 = "redis:stream:consumer1:";

    //redis的stream消费者2
    public static final String REDIS_STREAM_CONSUMER_2 = "redis:stream:consumer2:";

}
